5190174084e45c1d06f35e50c0ee7f1bf38d837d,examples/src/main/java8/org/apache/ignite/examples/MessagingExample.java,MessagingExample,startListening,#ClusterGroup#,102

Before Change


     */
    private static void startListening(ClusterGroup prj) throws IgniteException {
        // Add ordered message listener.
        prj.message().remoteListen(TOPIC.ORDERED, (nodeId, msg) -> {
            System.out.println("Received ordered message [msg=" + msg + ", fromNodeId=" + nodeId + ']');

            try {
                // Projection does not contain local node: ClusterGroup rmtPrj = g.forRemotes();
                // So, need to get projection for sender node through entire cluster.
                prj.ignite().forNodeId(nodeId).message().send(TOPIC.ORDERED, msg);
            }
            catch (IgniteException e) {
                e.printStackTrace();
            }

            return true; // Return true to continue listening.
        }).get();

        // Add unordered message listener.
        prj.message().remoteListen(TOPIC.UNORDERED, (nodeId, msg) -> {

After Change


     */
    private static void startListening(final Ignite ignite, IgniteMessaging imsg) throws IgniteException {
        // Add ordered message listener.
        imsg.remoteListen(TOPIC.ORDERED, (nodeId, msg) -> {
            System.out.println("Received ordered message [msg=" + msg + ", fromNodeId=" + nodeId + ']');

            try {
                ignite.message(ignite.cluster().forNodeId(nodeId)).send(TOPIC.ORDERED, msg);
            }
            catch (IgniteException e) {
                e.printStackTrace();
            }

            return true; // Return true to continue listening.
        });

        // Add unordered message listener.
        imsg.remoteListen(TOPIC.UNORDERED, (nodeId, msg) -> {